#pragma once
#include <IceUtil\Thread.h>
#include "IXRequestJob.h"

namespace Xts
{
	namespace Util
	{
		//Consumer Thread Class for Thread Safe Producer-Consumer model
		class XRequestReaderThread : public ::IceUtil::Thread
		{
		public:
			XRequestReaderThread(const XRequestQueuePtr& pRequestJobQueue);
			~XRequestReaderThread(void);

			virtual void run();

		protected:
			XRequestQueuePtr x_pRequestJobQueue;
		};
	}
}


